package com.bd08.flink.demo.jing.table

import org.apache.flink.api.scala.ExecutionEnvironment

object TableDemo2 extends App {
//  val benv = ExecutionEnvironment.getExecutionEnvironment
//  val tenv = BatchTableEnvironment.create(benv)
//  val ds=benv.fromElements(("Jason","9","2010-1-1"),("Tom","9","2010-1-1"))
//  tenv.registerDataSet("users",ds,'name,'age,'rowtime)
//  val tb=tenv.scan("users")
//  tb.printSchema()
//  tb.select('*).toDataSet[Row].print()  //'*表示所有字段


}
